d9ecbea9ea8f9ea8d01af7b4b0f0014bbc8e0a02,app/src/main/java/chat/rocket/android/service/RealmBasedConnectivityManager.java,RealmBasedConnectivityManager,waitForDisconnected,#String#,193

Before Change


        .filter(serverConnectivity -> (hostname.equals(serverConnectivity.hostname)
            && serverConnectivity.state == ServerConnectivity.STATE_DISCONNECTED))
        .first()
        .map(serverConnectivity -> true)
        .toSingle();
  }

  private Single<Boolean> connectToServer(String hostname) {

After Change


  private Single<Boolean> waitForDisconnected(String hostname) {
    return connectivitySubject
        .filter(serverConnectivity -> hostname.equals(serverConnectivity.hostname))
        .map(serverConnectivity -> serverConnectivity.state)
        .filter(state -> state == ServerConnectivity.STATE_DISCONNECTED)
        .first()
        .toSingle()
        .map(state -> true);
  }

  @DebugLog